package com.chuan.jms.cosumer;

import java.io.Serializable;

/**
 * Created by zhaowenchuan on 2018/11/1.
 */
public class ConsumerThread implements Runnable, Serializable {

    private Object tesk;

    public ConsumerThread(Object tesk) {
        this.tesk = tesk;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread().getName() + "is running"
                + " 系统时间：" + System.currentTimeMillis()
                + " 消费MQ：" + this.tesk);
    }
}
